package com.itlong.cloud.commons.queue;

import com.itlong.cloud.POJO.PO.AmountChangeInfoPO;
import org.springframework.stereotype.Component;

import java.util.concurrent.BlockingQueue;
import java.util.concurrent.LinkedBlockingQueue;

/**
 * <desc>
 *      更新资金变动明细表金额自定义队列
 * </desc>
 *
 * @createDate 2018/09/26
 */
@Component
public class UpdateAmountChangeInfoQueue {
    //更新项目金额阻塞队列
    private BlockingQueue<AmountChangeInfoPO> updateAmountChangeInfo = new LinkedBlockingQueue<>();//资金变动明细表队列

    public BlockingQueue<AmountChangeInfoPO> getUpdateAmountChangeInfoQueue() {
        return updateAmountChangeInfo;
    }
}
